<?php

namespace common\behavior;

use Webman\Stomp\Client;

/**
 * 任务废除启用事件 异步检查实体的状态
 */
class TaskCloseOperateAsyncCheckEntityStatusBehavior
{

    public function run($params)
    {
        Client::send('check_entity_status', build_queue_data_with_xu(['entity_id' => $params['task']['source_entity_id']]), 1);
    }
}
